# -*- coding: utf-8 -*-
# __author__ = 'cc'

import os
import sys
from pyspark import SparkContext
from pyspark import SparkConf
from pyspark.sql import SQLContext

master_url = 'local'
conf = SparkConf().setMaster(master_url).setAppName('Demo')
sc = SparkContext(conf=conf)
sql = SQLContext(sc)
df = sql.read.csv('test/train.csv',header=True)
print df.columns
